package srzy.socket

abstract class RBMsgAction {

}

abstract class RBMsgSleepAction extends RBMsgAction {
  val time: Int
}

abstract class RBMsgSleepAndDiscardAction extends RBMsgAction {
  val time: Int
}

object RBMsgActionQueue {
  val queue = new java.util.concurrent.ConcurrentLinkedQueue[RBMsgAction]
  def apply() = queue
}